package com.example.rabbitdemo.listenner;

import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.kafka.annotation.KafkaListener;

//@Component
//@Slf4j
public class KafkaListenner {

    @KafkaListener(topics = "topic1")
    public void listenKfk(ConsumerRecord<?, ?> cr){
        System.out.println("listenT1收到消息！！   topic:>>>  " + cr.topic() + "    key:>>  " + cr.key() + "    value:>>  " + cr.value());

    }
}
